package com.gtp.kafka.demo;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

//测试
@RestController
@RequestMapping("/kafka")
public class TestController {

	@Autowired
	private KafkaService kafkaService;

	@RequestMapping("/t1")
	@ResponseBody
	public String test1() {
		kafkaService.toSend();
		return "ok";
	}
}
